两款开源.NET工作流引擎 Elsa 与ccflow使用比较

​

相对java开源的工作流程引擎.net开源的工作流程引擎相对较少，这里整理两款.net开源工作流引擎，做一下对比使用。

elsa示例代码:

Githubd地址：https://github.com/zhenl/MyElsa

ccflow下载地址：https://gitee.com/opencc/ccflow

ccflow是国产的一款流程引擎，好在中文文档，名词概念符合中国人的理解习惯，文档视频教程较多，官网都是开放的。Ccflow对国产化支持较好，国内乱七八糟的数据库兼容。

ccflow与表单引擎结合在一起，深化了的应用场景的融合，配置大于代码开发这也是设计者的设计理念吧。可以做为中间件的模式与自己的系统开发框架集成，支持基础的以代码驱动流程运转。

安装与集成，参考他们的手册，下载下来，直接安装上即可，比较顺利与其它软件安装不同的是，自动生成数据库，没有提供数据库脚本，创建一个新的数据库修改一下数据库连接即可,按照向导执行安装。

参考视频教程一步步的创建一个流程，功能点太丰富，主要击中在节点属性，流程属性上，这也是国产软件的“通病”吧，猛地感觉上手困难。

Ccflow的接口在流程属性里有定义，分为Url调用接口，sdk开发接口。

登录与门户API

// 如下代码需要写入您的系统校验密码与用户名之后。string userNo = "zhangsan"; BP.WF.Dev2Interface.Port_Login(userNo);菜单

发起: //获得指定人员的可以发起的流程列表,调用这个接口返回一个datatable, 可以参考一个demo实现发起列表的输出。

System.Data.DataTable dtStart = BP.WF.Dev2Interface.DB_GenerCanStartFlowsOfDataTable("zhangsan");待办： //获得指定人员的待办,调用这个接口返回一个datatable, 可以参考一个demo实现发起列表的输出。DataTable dtTodolist = BP.WF.Dev2Interface.DB_GenerEmpWorksOfDataTable();在途： //获得指定人员的在途,调用这个接口返回一个datatable ，代码参考：。DataTable dtRuning = BP.WF.Dev2Interface.DB_GenerRuning();查询： //ccbpm给你提供了一个link ，您可以调用这个link ,也可以自己去根据代码实现。

实现列表输出代码，请参考:

运行Demo: ​​查询​​创建WorkID

//传入流程编号，调用创建一个工作ID。Int64 workid = BP.WF. Dev2Interface.Node_CreateBlankWork("001");发送 - 简单发送

//传入流程编号, WorkID执行发送. BP.WF.SendReturnObjs objs= BP.WF.Dev2Interface.Node_SendWork("001",workid);

// 检查流程是否结束？bool isFlowOver = objs.IsStopFlow;

// 获得发送到那个节点上去了？int toNodeID = objs.VarToNodeID;string toNodeName = objs.VarToNodeName;

// 获得发送给谁了？ 注意：这里如果是多个接受人员就会使用逗号分开。string toEmpID = objs.VarAcceptersID;string toEmpName = objs.VarAcceptersName;

// 输出提示信息, 这个信息可以提示给操作员.string infoMsg = objs.ToMsgOfHtml();

发送 - 要指定发送给谁？发送到那个节点？(万能发送接口)

//如果确定了（或者自己计算好了）下一步要达到的节点，下一步的接受人，就可以按照如下格式调用。 BP.WF.SendReturnObjs objs = null; objs = BP.WF.Dev2Interface.Node_SendWork("001", workid, 103, "zhangsan" );//发送给一个人,如果发送给多个人用逗号分开比如: zhangsan,lisi,wangwu

//下面调用方式，是知道要发送到那一个节点，但是不知道要发送给谁，让当前的节点定义的接受人规则来确定。 objs = BP.WF.Dev2Interface.Node_SendWork("001", workid, 103, null);

//下面调用方式，是知道要发送到那些人，但是不知道要发送到那个节点，让当前的节点定义的网关来确定。 objs = BP.WF.Dev2Interface.Node_SendWork("001", workid, 103,"zhangsan");

// 输出提示信息, 这个信息可以提示给操作员.string infoMsg = objs.ToMsgOfHtml(); 撤销

/* *执行撤销，返回撤销是否成功信息，如果抛出异常就说明撤销失败。 *撤销失败的原因多种，最有可能的是因为当前活动节点不允许撤销规则决定的。 */string msg= BP.WF.Dev2Interface.Flow_DoUnSend( workID); 回滚

//执行回滚，返回的是回滚执行信息，如果回滚失败，则会抛出异常。string msg= BP.WF.Dev2Interface.Flow_DoRebackWorkFlow("001", workID, 103, "因为审批错误，需要回滚，从节点103重新开始审批。");退回

/* * 1, 获得当前节点可以退回的节点，该接口返回一个datatable。 * 2, 一个节点能够退回到那写节点是由当前节点的退回规则确定的。 * 3, 调用退回需要三个参数：节点编号，工作ID, 流程ID, 对于线性流程FID始终等于0. */ System.Data.DataTable dtCanReturnNodes = BP.WF.Dev2Interface.DB_GenerWillReturnNodes(103, workid, 0);// 返回的是可以退回的节点。

//执行退回，当前的节点是103，要退回的节点是105，string msg = BP.WF.Dev2Interface.Node_ReturnWork("001", workid, 0, 103, 105, "您的申请信息不完整，请修改后重新发送。", false); 移交

/* * 调用移交接口，传入必要的参数执行移交. * FID 在线性流程上始终等于0. */ BP.WF.Dev2Interface.Node_Shift("001", 103, workid, 0, "zhangsan", "因我需要出差，所以特把工作移交给您。"); /* * 撤销移交 * 如果在移交之后，发现不需要移交，就需要撤销回来，调用撤销移交接口。 */BP.WF.Dev2Interface.Node_ShiftUn("001", workid);加签

/* * 调用加签接口，传入必要的参数执行. * FID 在线性流程上始终等于0. *///技术人员zhangsan接受工作后，点击发送还会发送给当前人员，由当前人员发送给下一节点。string info1= BP.WF.Dev2Interface.Node_Askfor(workid, BP.WF.AskforHelpSta.AfterDealSendByWorker, "zhangsan", "这里需要您出具技术鉴定意见.");

//技术人员填写后，直接就发送了下一节点.string info2 = BP.WF.Dev2Interface.Node_Askfor(workid, BP.WF.AskforHelpSta.AfterDealSend, "zhangsan", "这里需要您出具技术鉴定意见.");

//技术人员回复加签，在由当前人发送到下一个节点。string infoReply = BP.WF.Dev2Interface.Node_AskforReply("001", 103, workid,0, "我已经出具了技术鉴定意见，请参考.");结束流程

/* * 手工的结束流程,这种方式会记录日志. */string overInfo = BP.WF.Dev2Interface .Flow_DoFlowOver( workID, "该供应商找不到了，要结束掉该流程。"); /* * 删除流程, * 删除流程有多种方式，用户可以根据自己的需求，调用不同的方式. * 最后一个参数是是否删除子流程. */

//按照标记删除流程string delInfo0 = BP.WF.Dev2Interface .Flow_DoDeleteFlowByFlag( workID, "我不需要请假了", true);

//彻底的删除流程，无日志记录.string delInfo1 = BP.WF.Dev2Interface .Flow_DoDeleteFlowByReal( workID, "我不需要请假了", true);

//彻底的删除流程,有日志记录.string delInfo2 = BP.WF.Dev2Interface .Flow_DoDeleteFlowByWriteLog("001", workID, "我不需要请假了", true);

在流程属性里提供了开发接口demo, 这是提供开发者用的，需要写一个子类，然后编译里ddl里面去，通过反射，流程在运行的过程中，可以调用它。

开发人员只要重写这些事件方法即可，比如发送前，发送成功时，发送失败时，流程结束前，结束后，退回前，退回后等等。

微软的Workflow Foundation基于.NET Framework，并且没有向.NET Core迁移的计划。

我们的很多项目使用了工作流引擎，这些项目向.NET Core以及更高版本迁移时遇到了不少问题，一直在寻找/开发适合的工作流引擎。

找到一些开源的项目，可以解决一些问题，还有些项目不是基于.NET生态的，但我希望能有一个长期稳定的基于.NET生态的项目，能够满足多种场景，可以替换原来的Workflow Foundation。

1、同时支持编程工作流定义和配置工作流定义，最好有图形化的管理工具。

2、支持长期工作流。

3、支持有限状态机类型的工作流定义。

4、工作流引擎可以集成在应用中，也可以独立部署为工作流服务器，采用Web API的方式调用。

在我们跟踪的工作流相关项目中，Elsa一直在稳步发展，最新的版本（2.9）已经基本可以满足我们的上述要求了，在以后的版本也会增加对有限状态机的支持。

这里简单介绍一下如何创建工作流服务器和图形化的工作流配置管理应用。

首先，使用Visual Studio 2022创建一个空的ASP.NET Core Web应用，名称为MyElsaServer。

项目创建完成后，使用NuGet包管理器，安装如下程序包：

Install-Package Elsa

Install-Package Elsa.Activities.Http

Install-Package Elsa.Persistence.EntityFramework.Sqlite

Install-Package Elsa.Server.Api

然后，修改项目的Properties/launchSettings.json，去掉通过IIS Express启动的选项:

{

}

最后，修改Program.cs：

using Elsa.Persistence.EntityFramework.Core.Extensions;

using Elsa.Persistence.EntityFramework.Sqlite;

var builder = WebApplication.CreateBuilder(args);

var elsaSection = builder.Configuration.GetSection("Elsa");

// Elsa services.

builder.Services

// Elsa API endpoints.

builder.Services.AddElsaApiEndpoints();

// Allow arbitrary client browser apps to access the API.

// In a production environment, make sure to allow only origins you trust.

builder.Services.AddCors(cors => cors.AddDefaultPolicy(policy => policy

);

var app = builder.Build();

app

app.Run();

最后，在appSettings.json中增加服务器地址的定义：

启动项目，会出现欢迎界面：

服务器可以运行了，但还没有定义工作流，现在我们创建图形化的工作流定义和管理应用，向工作流服务器发布工作流，并查看工作流的执行情况。

在解决方案中增加一个新的ASP.NET Core Web空项目，命名为MyElsaDashboard，修改Properties/launchSettings.json,将项目改为自启动:

{

}

在项目中添加如下程序包：

Install-Package Elsa.Designer.Components.Web

修改Program.cs：

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddRazorPages();

var app = builder.Build();

app.UseStaticFiles();

app.UseRouting();

app.UseEndpoints(endpoints => { endpoints.MapFallbackToPage("/_Host"); });

app.Run();

然后在项目中创建Pages文件夹，在文件夹中添加两个Razepage页面，名称为_ViewImports.cshtml和_Host.cshtml，_ViewImports的内容如下：

@ addTagHelper *, Microsoft .AspNetCore.Mvc.TagHelpers

_Host.cshtml的内容如下：

@page "/"

请注意上面的server-url属性，这里指向我们前面创建的Elsa服务器地址。

现在我们修改解决方案的启动项目，设置为两个项目同时启动：

在Visual Studio中执行启动，管理界面如下：

选择Workflow Definitions进入流程定义管理界面，点击“Create Workflow”创建新的流程：

点击Start,然后选择Http->Http EndPoint,定义流程的入口url:

设置完成后按Save保存，可以看到多个一个环节，在这个环节下点击“+”图标可以继续添加环节，这里选择HttpResponse:

在Advanced选择卡中，选择Status Code为Ok，添加完成后，流程如下：

流程定义完成了，点击Publish发布流程到流程服务器。

流程发布后，可以在流程服务器执行流程。

我们在浏览器访问http://localhost:5298/hello-world，可以看到流程执行的结果：

回到流程管理应用，选择Workflow Instances,可以看到刚刚执行完成的流程实例：

点击流程Id,可以查看流程执行的详细过程：

到此，我们完成了工作流服务和管理应用的创建。

示例代码

Githubd地址：https://github.com/zhenl/MyElsa